object Streaming {
  def main(args: Array[String]): Unit = {
    object SparkStreaming_1 {
      def main(args: Array[String]): Unit = {
        val sparkConf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount")
        val ssc = new StreamingContext(sparkConf, Seconds(5))
        val dStream: ReceiverInputDStream[String] =
          ssc.socketTextStream("localhost", 9999)
        val lines: DStream[String] = dStream.flatMap(_.split(" "))
        val wordDStream: DStream[(String, Int)] = lines.map((_, 1))
        val result = wordDStream.reduceByKey(_ + _)
        result.print()
        ssc.start()
        ssc.awaitTermination()
      }
    }
  }

}
